//package com.utils.redis;
//
//import com.utils.redis.utils.ByteObjectConvertUtil;
//import com.utils.redis.utils.JedisSimpleUtils;
//import org.apache.flink.api.java.tuple.Tuple1;
//import org.apache.flink.types.Row;
//import redis.clients.jedis.Jedis;
//import redis.clients.jedis.Tuple;
//
//import java.util.ArrayList;
//import java.util.List;
//
///**
// * @author xin.ding
// * @date 2020/9/22 17:30
// */
//public class RowRedisTest {
//    private  static Jedis jedis;
//
//    public static void main(String[] args) {
//         jedis = JedisSimpleUtils.getJedisClient();
//
//        Row row1 = Row.of(1, 2, 3);
//        Row row2 = Row.of("a", "b", "c");
//
//        Tuple1<String> key = Tuple1.of("1");
//
//        List<Row> value = new ArrayList<>(16);
//        value.add(row1);
//        value.add(row2);
//        for (int i = 0; i <1000000 ; i++) {
//            Row row = Row.of(i);
//            value.add(row);
//        }
//        setValue(key, value);
//        List<Row> value1 = getValue(key);
//        for (Row row : value1) {
//            System.out.println("cache : "+row);
//        }
//    }
//
//    public static void setValue(Tuple1<String> key, List<Row> value) {
////        String redisKey = ByteObjectConvertUtil.getBytesFromObject(key);
//        String redisKey =key.toString();
//        String redisValue = ByteObjectConvertUtil.getBytesFromObject(value);
//        jedis.set(redisKey,redisValue);
//    }
//
//    public static List<Row> getValue(Tuple1<String> key){
////        String redisKey = ByteObjectConvertUtil.getBytesFromObject(key);
//        String redisKey =key.toString();
//        String s = jedis.get(redisKey);
//        List<Row> objectFromBytes = (List<Row>) ByteObjectConvertUtil.getObjectFromBytes(s);
//        return objectFromBytes;
//    }
//}
